package com.example.demo.webflux;

import com.example.demo.webflux.entity.UserEntity;
import com.example.demo.webflux.service.UserService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;

/**
 * webflux service
 *
 * @author huangchangjin
 * @date 2025/9/8 17:15
 */
@Slf4j
@Service
public class MyWebFluxService {
    @Resource
    private UserService userService;

    public Flux<UserEntity> findAll() {
        return userService.findAll();
    }
}
